package com.esir.harmony.bus;

import io.reactivex.rxjava3.core.Observer;
import ohos.aafwk.ability.Lifecycle;

import static ohos.aafwk.ability.Lifecycle.Event.ON_STOP;

public class LiveData<T> implements MutableLiveData<T> {
    public void observe(Lifecycle owner, Observer<? super T> observer) {
        assertMainThread("observe");
        if (owner.getLifecycleState() == ON_STOP) {
            // ignore
            return;
        }

    }

    static void assertMainThread(String methodName) {
    }

    @Override
    public void postValue(T value) {

    }

    @Override
    public void setValue(T value) {

    }
}
